package cn.bq;

import java.util.concurrent.BlockingQueue;

public class Consumer extends Thread{
	  private BlockingQueue<Food> bqueue;
		public Consumer(BlockingQueue<Food> queue){
			this.bqueue=queue;
		}
		@Override
		public void run(){
			while(true){
				try {
					@SuppressWarnings("unused")
					Food food=bqueue.take();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println("take one");
			}
		}
}
